package top.codecrab.eblog.utils;

import lombok.RequiredArgsConstructor;
import org.springframework.amqp.AmqpException;
import org.springframework.stereotype.Component;

/**
 * @author 王刚
 * @since 2022年08月09日 12:17
 */
@Component
@RequiredArgsConstructor
public class AmqpUtil {

//    private final AmqpTemplate amqpTemplate;

    /**
     * 发送消息到rabbitmq
     */
    public void sendMsg(String routingKey, Long id) {
        try {
            //捕获异常，消息发送成功与否不能影响方法本身的事务
            // amqpTemplate.convertAndSend(routingKey, id);
        } catch (AmqpException e) {
            e.printStackTrace();
        }
    }

}
